# -*- coding: utf-8 -*-
from datetime import timedelta

from airflow.providers.apache.hdfs.sensors.web_hdfs import WebHdfsSensor

jms_dm__dm_route_recommend = WebHdfsSensor(
    pool='unlimited_pool',
    task_id="jms_dm__dim_yl_tmsnew_tms_out_warehouse_sh_base",
    filepath='/dw/hive/jms_dm.db/external/dm_route_recommend/dt={{ execution_date | date_add(-2) | cst_ds }}',
    execution_timeout=timedelta(hours=7),
    email={'guoruiling@jtexpress.com','yl_bigdata@yl-scm.com'},
    retries=2,
)
